from celery import Celery
import time
celery_app = Celery('hello', broker='redis://121.196.236.225:9379/0')
# 创建任务函数
@celery_app.task
def my_task1():
    print("任务函数(my_task1)正在执行....")
 
@celery_app.task
def my_task2():
    print("任务函数(my_task2)正在执行....")
 
@celery_app.task
def my_task3():
    print("任务函数(my_task3)正在执行....")

my_task1.delay()

print("---e")

time.sleep(10)